import celery_task

# 1 同步执行
# res = celery_task.add(2, 3)  # 普通的同步任务，同步执行
# print(res)

# 2 异步任务
# 2.1
# 第一步提交任务(用任务名.apply_async)
# 返回的结果是任务的id号，唯一标识这个任务
# res = celery_task.add.apply_async(kwargs={'a':1, 'b':2})
res = celery_task.add.apply_async(args=[1, 2])
print(res)


# 2.2
# 第二步：让worker执行-->结果存到redis
# 通过命令启动
# 非windows
# 5.x前启动命令
# celery worker -A celery_task -l info
# 5.x后启动命令
# celery -A celery_task worker -l info

# windows
# pip3 install eventlet
# 5.x前启动命令
# celery worker -A celery_task -l info -P eventlet
# 5.x后启动命令
# celery -A celery_task worker _l info -P eventlet

# 第三步:查看任务执行结果
